// @Author EthanScriptOn
// @Desc
package extend_config

import (
	"github.com/apache/rocketmq-client-go/v2/primitive"
	"github.com/confluentinc/confluent-kafka-go/kafka"
	"github.com/streadway/amqp"
)

type KafkaOperatorResponse struct {
	Partition int32
	Offset    int64
	Err       error
	OriginMsg *kafka.Message
}

type RabbitmqOperatorResponse struct {
	Err        error
	Exchange   string
	Routingkey string
	OriginMsg  *amqp.Publishing
}

type RedisExecOperatorResponse struct {
	Err       error
	OriginMsg string
}

type RedisQueryOperatorResponse struct {
	Err    error
	Result string
}

type RocketmqOperatorResponse struct {
	Response  *primitive.SendResult
	Err       error
	OriginMsg *primitive.Message
}

type LocalWriteOperatorResponse struct {
	Err       error
	OriginMsg string
	FilePath  string
}
